package com.qfedu.edu.constance;

/**
 * @author xiaobobo
 * @title: RabbitMQConctanse
 * @projectName cd-fy-2401-third-project-parent
 * @description: MQ相关的常量
 * @date 2024/10/9  16:59
 */
public class RabbitMQConstance {

    //队列中消息个数的积压预警的阈值
    private static final Integer QUEUE_MESSAGE_LIMIT=10000;


    public static Integer getQueueMessageLimit() {
        return QUEUE_MESSAGE_LIMIT;
    }

    //硬件发送消息给消息中心的中转队列
    //这个队列的名字是用在监控消息的积压
    private static final String[] QUEUE_NAMES_ARRAY={
          "emqxQueue","exceptionQueue"
    };

    public static String[] getQueueNamesArray() {
        return QUEUE_NAMES_ARRAY;
    }

    private static final String HARDWARE_MESSAGE_QUEUE="emqxQueue";



    public static String getHardwareMessageQueue() {
        return HARDWARE_MESSAGE_QUEUE;
    }
}
